github.com/go-pg/pg/v10.Listener.db (field)

14 uses

	github.com/go-pg/pg/v10 (current package)
		db.go#L80: 		db: db,
		listener.go#L33: 	db *DB
		listener.go#L86: 	cn, err := ln.db.pool.NewConn(ctx)
		listener.go#L91: 	if err := ln.db.initConn(ctx, cn); err != nil {
		listener.go#L92: 		_ = ln.db.pool.CloseConn(cn)
		listener.go#L101: 			_ = ln.db.pool.CloseConn(cn)
		listener.go#L130: 		internal.Logger.Printf(ln.db.ctx, "pg: discarding bad listener connection: %s", reason)
		listener.go#L133: 	err := ln.db.pool.CloseConn(ln.cn)
		listener.go#L173: 	err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
		listener.go#L175: 			if err := writeQueryMsg(wb, ln.db.fmter, "LISTEN ?", pgChan(channel)); err != nil {
		listener.go#L206: 	err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
		listener.go#L208: 			if err := writeQueryMsg(wb, ln.db.fmter, "UNLISTEN ?", pgChan(channel)); err != nil {
		listener.go#L275: 	ctx := ln.db.ctx
		listener.go#L365: 	_, err := ln.db.Exec("NOTIFY ?", pgChan(gopgChannel))